from celery.schedules import crontab
from celery_task.main import app


broker_url = "redis://127.0.0.1:6379/11"   # 使用redis存储任务队列
result_backend = "redis://127.0.0.1:6379/12"  # 使用redis存储结果

task_serializer = "json"
result_serializer = "json"
accept_content = ["json"]
timezone = "Asia/Shanghai"  # 时区设置
worker_hijack_root_logger = False  # celery默认开启自己的日志，可关闭自定义日志，不关闭自定义日志输出为空
result_expires = 60 * 60 * 24  # 存储结果过期时间（默认1天）


"""设置Celery自动捕获异步任务"""
app.autodiscover_tasks([
    "celery_task.tasks",
])


"""定时任务导入"""
imports = [
    "celery_task.tasks.html",  # 导入py文件
]

"""定时任务设置"""
beat_schedule = {
    "html": {
        "task": "celery_task.tasks.html.generate_static_sku_detail_html",  # 执行的函数
        "schedule": crontab(minute="*/1"),  # every minute 每分钟执行
        "args": (66,)  # 任务函数参数
    },
}
